package cn.itcast.n8;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.*;

@Slf4j(topic = "c.TestLinkedBlockingQueue")
public class TestLinkedBlockingQueue {
    public static void main(String[] args) throws InterruptedException {
        final LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>();
        final ConcurrentLinkedQueue<Integer> integers = new ConcurrentLinkedQueue<>();
        final ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<Integer>(3);

        final CopyOnWriteArraySet<Integer> arraySet = new CopyOnWriteArraySet<>();
        final CopyOnWriteArrayList<Integer> arrayList = new CopyOnWriteArrayList<>();

        arrayBlockingQueue.put(1);
        arrayBlockingQueue.put(1);
        arrayBlockingQueue.put(1);
        arrayBlockingQueue.put(1);
    }
}
